package com.ds.msg.mqtt.client;

import com.ds.annotation.JLuceneIndex;
import com.ds.common.Condition;
import com.ds.config.ListResultModel;
import com.ds.config.ResultModel;
import com.ds.msg.RMsg;
import com.ds.org.query.MsgConditionKey;

import java.util.List;

public interface MqttService {

    public ListResultModel<List<RMsg>> loadMsgs(String[] msgId);

    public ResultModel<RMsg> getMsgById(String msgId);

    public ListResultModel<List<String>> findMsgIds(Condition<MsgConditionKey, JLuceneIndex> condition) ;

    public ResultModel<Boolean>  updateMsg(RMsg msg);

    public ResultModel<Boolean>  deleteMsg(String msgId);

    public ResultModel<Boolean>  deleteMsgs(String[] msgIds);
}
